package org.cancer.controller

import org.apache.spark.streaming.dstream.DStream
import org.cancer.bean.CancerTypeDeathData_Faye
import org.cancer.service.CancerTypeDeathService_Faye

class CancerTypeDeathController_Faye {
  val cTDeathService_Faye = new CancerTypeDeathService_Faye()

  def dispatch(data: DStream[CancerTypeDeathData_Faye]): Unit = {
    cTDeathService_Faye.dataAnalysis(data)
  }
}
